88407d1e949de4bd404dedb62c67377767b5f6b4,bridge/src/main/java/io/rhiot/kafka/bridge/SourceBridgeEndpoint.java,SourceBridgeEndpoint,close,#,88
Before Change
if (this.ebConsumer != null)
this.ebConsumer.unregister();
this.vertx.sharedData().getLocalMap(this.ebName).clear();
}
@Override
After Change
if (this.producerSettledMode != null)
this.producerSettledMode.close();
if (this.producerUnsettledMode != null)
this.producerUnsettledMode.close();
if (this.ebConsumer != null)
this.ebConsumer.unregister();
if (this.ebName != null)
this.vertx.sharedData().getLocalMap(this.ebName).clear();
}
@Override